package cn.monkey.transport.core.client;

import cn.monkey.transport.core.Exchange;
import reactor.core.publisher.Mono;

import java.net.SocketAddress;

public interface Client<EXCHANGE extends Exchange> {
    Mono<EXCHANGE> connect(SocketAddress socketAddress);

    Mono<Void> close(SocketAddress socketAddress);

    EXCHANGE getExchange(SocketAddress socketAddress);
}
